package com.imooc.chart.util;

import io.netty.channel.Channel;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.concurrent.GlobalEventExecutor;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class SessionHolder {

    /**
     * 储存每个客户端接入进来时的 channel 对象
     * 主要用于 writeAndFlush 方法广播信息
     */
    public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    /**
     * 用于客户端和服务端握手时存储 用户id 和 netty Channel对应关系
     */
    public static Map<String, Channel> channelMap = new ConcurrentHashMap<>();

}
